# 将下一个版本中更新的内容导入到当前版本中
from __future__ import absolute_import, unicode_literals
import os
from celery import Celery
from datetime import timedelta
from celery.schedules import crontab

os.environ.setdefault('DJANGO_SETTINGS_MODULE', 'RepliceProject.settings')  # 设置django环境  Orm_Mysql是project名称

app = Celery('RepliceProject') #还有这里

app.config_from_object('django.conf:settings', namespace='CELERY')  # 使用CELERY_ 作为前缀，在settings中写配置

app.autodiscover_tasks()  # 发现任务文件每个app下的task.py

# 声明定时任务
app.conf.beat_schedule = {
    u'app01_tasks_add': {		# 任务名，可以自定义
        "task": "app01.tasks.add",	# 任务函数
        "schedule": timedelta(seconds=10),	# 定时每10秒执行一次
        # "args": (1, 3),		# 传未定义的不定长参数
        # 'kwargs': ({'name':'张三'}),	# 传已定义的不定长参数
    },
    u'app01_tasks_mcn_name': {
        "task": "app01.tasks.mcn_name",
        "schedule": timedelta(seconds=15),		# 定时每15秒执行一次
        # "args": (),
        # 'kwargs': (),
    },
    # u'app01_tasks_mcn_gov': {
    #         "task": "app01.tasks.mcn_gov",
    #         "schedule": timedelta(seconds=20),		# 定时每20秒执行一次
    #         # "args": (),
    #         # 'kwargs': (),
    #     },
}

